package com.audaque.springboot.foshanupload.web.flinkdemo.service.inface;

/**
 * @author zgb
 * @desc ...
 * @date 2023-08-21 22:21:02
 */
public interface FlinkService {

    void textSplitWordCountByDataSet() throws Exception;
    void textSplitWordCountByDataStream() throws Exception;
    void textSplitWordCountByDataStreamFromSocket() throws Exception;

    void kafka2mongodb()  throws Exception;

}
